<?php
require_once __DIR__ . '/../vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPStreamConnection;
class receive
{
    public function __construct()
    {
        self::receive();
    }

    public static function receive()
    {
        $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
        $channel = $connection->channel();
        /**
         * 生成一个队列
         * 1、队列名称
         * 2、队列里面的消息是否持久化（磁盘 - true），默认情况下，消息存储在内存中
         * 3、该队列是否只供一个消费者进行消费 是否进行消息共享，true 可以多个消费者消费，默认情况下不共享
         * 4、是否自动删除 最后一个消费者断开连接以后 该队列是否自动删除 true 自动删除，false 不删除
         * 5、其他参数
         */
        $channel->queue_declare('hello', false, false, false, false);

        echo " [*] Waiting for messages. To exit press CTRL+C\n";

        $callback = function ($msg) {
            echo ' [x] Received ', $msg->body, "\n";
        };

        /**
         * 生成一个队列
         * 1、队列名称
         * 2、交换机
         * 3、
         * 4、消费成功后是否要自动应答 true 代表自动应答 false 代表手动应答
         * 5、
         * 6、消费者未成功消费的回调
         * 7、消费者成功消费的回调
         */
        $channel->basic_consume('hello', '', false, true, false, false, $callback);

        while ($channel->is_open()) {
            $channel->wait();
        }

        $channel->close();
        $connection->close();
    }
}


new receive();